package com.growthserver.kafkaMQ;//package com.ly.mp.growth.service;
//
//
//import com.alibaba.fastjson.JSON;
//import com.alibaba.fastjson.JSONObject;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Service;
//@Slf4j
//@Service
//public class mqConsoum {
//
//    @KafkaListener(topics ="TOPIC_BYCAR_INTEGRAL" ,groupId = "TOPIC_BYCAR_INTEGRAL-11")
//    public void ss(String message){
//        log.info("获取mq消息:{}",message);
//        JSONObject jsonObject = JSON.parseObject(message);
//        System.out.println("----------------");
//    }
//}
